CREATE TABLE jms_dm.dm_sqs_worn_waybill_detail_mid_dt
(
    work_type                 varchar(100) COMMENT '工单类型',
    waybill_no                varchar(100) COMMENT '运单号',
    resp_network_id           varchar(100) COMMENT '责任网点id',
    resp_network_code         varchar(100) COMMENT '责任网点code',
    work_order_code           varchar(100) COMMENT '理赔编号',
    finish_time               varchar(100) COMMENT '提交时间',
    submit_status             varchar(100) COMMENT '状态',
    is_carrier                varchar(100) COMMENT '是否承运商',
    source                    varchar(100) COMMENT '只要1-客服',
    resp_network_name         varchar(100) COMMENT '责任网点name',
    resp_network_id_2         varchar(100) COMMENT '责任网点id2',
    resp_network_code_2       varchar(100) COMMENT '责任网点code2',
    resp_network_name_2       varchar(100) COMMENT '责任网点name2',
    resp_network_id_3         varchar(100) COMMENT '责任网点id3',
    resp_network_code_3       varchar(100) COMMENT '责任网点code3',
    resp_network_name_3       varchar(100) COMMENT '责任网点name3',
    resp_network_id_4         varchar(100) COMMENT '责任网点id4',
    resp_network_code_4       varchar(100) COMMENT '责任网点code4',
    resp_network_name_4       varchar(100) COMMENT '责任网点name4',
    resp_network_id_5         varchar(100) COMMENT '责任网点id5',
    resp_network_code_5       varchar(100) COMMENT '责任网点code5',
    resp_network_name_5       varchar(100) COMMENT '责任网点name5',
    resp_proxy_id             varchar(100) COMMENT '责任代理区id',
    resp_proxy_code           varchar(100) COMMENT '责任代理区code',
    resp_proxy_name           varchar(100) COMMENT '责任代理区name',
    resp_proxy_id_2           varchar(100) COMMENT '责任代理区id2',
    resp_proxy_code_2         varchar(100) COMMENT '责任代理区code2',
    resp_proxy_name_2         varchar(100) COMMENT '责任代理区name2',
    resp_proxy_id_3           varchar(100) COMMENT '责任代理区id_3',
    resp_proxy_code_3         varchar(100) COMMENT '责任代理区code_3',
    resp_proxy_name_3         varchar(100) COMMENT '责任代理区name_3',
    resp_proxy_id_4           varchar(100) COMMENT '责任代理区id_4',
    resp_proxy_code_4         varchar(100) COMMENT '责任代理区code_4',
    resp_proxy_name_4         varchar(100) COMMENT '责任代理区name_4',
    resp_proxy_id_5           varchar(100) COMMENT '责任代理区id_5',
    resp_proxy_code_5         varchar(100) COMMENT '责任代理区code_5',
    resp_proxy_name_5         varchar(100) COMMENT '责任代理区name_5',
    create_network_id         varchar(100) COMMENT '申报网点id',
    create_network_code       varchar(100) COMMENT '申报网点code',
    create_network_name       varchar(100) COMMENT '申报网点name',
    create_parent_id          varchar(100) COMMENT '申报代理区id',
    create_parent_code        varchar(100) COMMENT '申报代理区code',
    create_parent_name        varchar(100) COMMENT '申报代理区name',
    problem_type_id           varchar(100) COMMENT '只要 1-遗失',
    problem_type_code         varchar(100) COMMENT '一级类型code',
    problem_type_name         varchar(100) COMMENT '一级类型name',
    problem_type_subject_id   varchar(100) COMMENT '二级类型id',
    problem_type_subject_code varchar(100) COMMENT '二级类型code',
    problem_type_subject_name varchar(100) COMMENT '二级类型name',
    goods_value               varchar(100) COMMENT '金额1',
    goods_value2              varchar(100) COMMENT '金额2',
    goods_value3              varchar(100) COMMENT '金额3',
    goods_value4              varchar(100) COMMENT '金额4',
    goods_value5              varchar(100) COMMENT '金额5',
    arb_create_time           varchar(100) COMMENT '仲裁申报时间',
    delay_day                 varchar(100) COMMENT '延误天数',
    status                    varchar(100) COMMENT '异常说明',
    arrival_time              varchar(100) COMMENT '责任网点到件时间',
    collect_time              varchar(100) COMMENT '揽收时间',
    handling_fee              varchar(100) COMMENT '手续费',
    valid_status              varchar(100) COMMENT '生效状态 1:生效 2:失效',
    rn                        int(11) COMMENT '每种工单的去重row_number()',
    flag                      int(11) COMMENT '仲裁1,线上理赔2,质量工单3',
    finish_type               varchar(100) COMMENT '完结类型',
    rm                        int(11) COMMENT '根据运单分组,flag排序,做dense_rank()',
    duty_network_type         varchar(100) COMMENT '责任网点网点类型(基础资料)',
    duty_virt_code            varchar(100) COMMENT '责任网点虚拟代理区code(基础资料)',
    duty_virt_name            varchar(100) COMMENT '责任网点虚拟代理区name(基础资料)',
    duty_is_virtual_agent     varchar(100) COMMENT '责任网点是否是虚拟代理区1是',
    duty_manage_code          varchar(100) COMMENT '责任网点管理大区名称(基础资料)',
    duty_manage_name          varchar(100) COMMENT '责任网点管理大区名称(基础资料)',
    duty_regional_id          varchar(100) COMMENT '责任网点大区ID(基础资料)',
    duty_regional_desc        varchar(100) COMMENT '责任网点大区name(基础资料)',
    duty_agent_code           varchar(100) COMMENT '责任网点代理区编码(基础资料)',
    duty_agent_name           varchar(100) COMMENT '责任网点代理区名称(基础资料)',
    duty_fran_code            varchar(100) COMMENT '责任网点加盟商编码(基础资料)',
    duty_fran_name            varchar(100) COMMENT '责任网点加盟商名称(基础资料)',
    duty_center_code          varchar(100) COMMENT '责任网点中心编码(基础资料)',
    duty_center_name          varchar(100) COMMENT '责任网点中心名称(基础资料)',
    duty_provider_id          varchar(100) COMMENT '责任网点省份ID(基础资料)',
    duty_provider_desc        varchar(100) COMMENT '责任网点省份(基础资料)',
    duty_city_id              varchar(100) COMMENT '责任网点城市ID(基础资料)',
    duty_city_desc            varchar(100) COMMENT '责任网点城市(基础资料)',
    duty_area_id              varchar(100) COMMENT '责任网点区/县id',
    duty_area_desc            varchar(100) COMMENT '责任网点区/县',
    duty_is_enable            varchar(100) COMMENT '责任网点状态 0待启用,1启用,2禁用',
    duty_is_suspend           varchar(100) COMMENT '责任网点是否暂停网点(1是,2否)',
    sb_manage_code            varchar(100) COMMENT '申报网点管理大区名称(基础资料)',
    sb_manage_name            varchar(100) COMMENT '申报网点管理大区名称(基础资料)',
    sb_regional_id            varchar(100) COMMENT '申报网点大区ID(基础资料)',
    sb_regional_desc          varchar(100) COMMENT '申报网点大区name(基础资料)',
    sb_network_type           varchar(100) COMMENT '申报网点网点类型(基础资料)',
    transfer_district_id      varchar(100) COMMENT '责任网点片区id',
    transfer_district_code    varchar(100) COMMENT '责任网点片区code',
    transfer_district_desc    varchar(100) COMMENT '责任网点片区desc',
    is_delete                 varchar(100) COMMENT '1代表需要的数据,未剔除',
    customer_code             varchar(100) COMMENT '客户编码',
    customer_name             varchar(100) COMMENT '客户名字',
    remark3                   varchar(100) COMMENT '备用',
    duty_manage_code_2        varchar(100) COMMENT '第二责任网点管理大区名称(基础资料)',
    duty_manage_name_2        varchar(100) COMMENT '第二责任网点管理大区名称(基础资料)',
    duty_regional_id_2        varchar(100) COMMENT '第二责任网点大区ID(基础资料)',
    duty_regional_desc_2      varchar(100) COMMENT '第二责任网点大区name(基础资料)',
    duty_agent_code_2         varchar(100) COMMENT '第二责任网点代理区编码(基础资料)',
    duty_agent_name_2         varchar(100) COMMENT '第二责任网点代理区编码(基础资料)',
    duty_network_type_2       varchar(100) COMMENT '第二责任网点网点类型(基础资料)',
    duty_provider_id_2        varchar(100) COMMENT '第二责责任网点省份ID(基础资料)',
    duty_provider_desc_2      varchar(100) COMMENT '第二责责任网点省份(基础资料)',
    duty_city_id_2            varchar(100) COMMENT '第二责责任网点城市ID(基础资料)',
    duty_city_desc_2          varchar(100) COMMENT '第二责责任网点城市(基础资料)',
    duty_area_id_2            varchar(100) COMMENT '第二责责任网点区/县id',
    duty_area_desc_2          varchar(100) COMMENT '第二责责任网点区/县',
    duty_is_enable_2          varchar(100) COMMENT '第二责责任网点状态 0待启用,1启用,2禁用',
    duty_is_suspend_2         varchar(100) COMMENT '第二责责任网点是否暂停网点(1是,2否)',
    transfer_district_id_2    varchar(100) COMMENT '第二责责任网点片区id',
    transfer_district_code_2  varchar(100) COMMENT '第二责责任网点片区code',
    transfer_district_desc_2  varchar(100) COMMENT '第二责责任网点片区desc',
    duty_virt_code_2          varchar(100) comment '第二责任网点虚拟代理区code(基础资料)',
    duty_virt_name_2          varchar(100) comment '第二责任网点虚拟代理区name(基础资料)',
    duty_is_virtual_agent_2   varchar(100) comment '第二责任网点是否是虚拟代理区1是',
    duty_manage_code_3        varchar(100) COMMENT '第三责任网点管理大区名称(基础资料)',
    duty_manage_name_3        varchar(100) COMMENT '第三责任网点管理大区名称(基础资料)',
    duty_regional_id_3        varchar(100) COMMENT '第三责任网点大区ID(基础资料)',
    duty_regional_desc_3      varchar(100) COMMENT '第三责任网点大区name(基础资料)',
    duty_agent_code_3         varchar(100) COMMENT '第三责任网点代理区编码(基础资料)',
    duty_agent_name_3         varchar(100) COMMENT '第三责任网点代理区编码(基础资料)',
    duty_network_type_3       varchar(100) COMMENT '第三责任网点类型(基础资料)',
    duty_provider_id_3        varchar(100) COMMENT '第三责任网点省份ID(基础资料)',
    duty_provider_desc_3      varchar(100) COMMENT '第三责任网点省份(基础资料)',
    duty_city_id_3            varchar(100) COMMENT '第三责任网点城市ID(基础资料)',
    duty_city_desc_3          varchar(100) COMMENT '第三责任网点城市(基础资料)',
    duty_area_id_3            varchar(100) COMMENT '第三责任网点区/县id',
    duty_area_desc_3          varchar(100) COMMENT '第三责任网点区/县',
    duty_is_enable_3          varchar(100) COMMENT '第三责任网点状态 0待启用,1启用,2禁用',
    duty_is_suspend_3         varchar(100) COMMENT '第三责任网点是否暂停网点(1是,2否)',
    transfer_district_id_3    varchar(100) COMMENT '第三责任网点片区id',
    transfer_district_code_3  varchar(100) COMMENT '第三责任网点片区code',
    transfer_district_desc_3  varchar(100) COMMENT '第三责任网点片区desc',
    duty_virt_code_3          varchar(100) comment '第三责任网点虚拟代理区code(基础资料)',
    duty_virt_name_3          varchar(100) comment '第三责任网点虚拟代理区name(基础资料)',
    duty_is_virtual_agent_3   varchar(100) comment '第三责任网点是否是虚拟代理区1是',
    duty_manage_code_4        varchar(100) COMMENT '第四责任网点管理大区名称(基础资料)',
    duty_manage_name_4        varchar(100) COMMENT '第四责任网点管理大区名称(基础资料)',
    duty_regional_id_4        varchar(100) COMMENT '第四责任网点大区ID(基础资料)',
    duty_regional_desc_4      varchar(100) COMMENT '第四责任网点大区name(基础资料)',
    duty_agent_code_4         varchar(100) COMMENT '第四责任网点代理区编码(基础资料)',
    duty_agent_name_4         varchar(100) COMMENT '第四责任网点代理区编码(基础资料)',
    duty_network_type_4       varchar(100) COMMENT '第四责任网点类型(基础资料)',
    duty_provider_id_4        varchar(100) COMMENT '第四责责任网点省份ID(基础资料)',
    duty_provider_desc_4      varchar(100) COMMENT '第四责责任网点省份(基础资料)',
    duty_city_id_4            varchar(100) COMMENT '第四责责任网点城市ID(基础资料)',
    duty_city_desc_4          varchar(100) COMMENT '第四责责任网点城市(基础资料)',
    duty_area_id_4            varchar(100) COMMENT '第四责责任网点区/县id',
    duty_area_desc_4          varchar(100) COMMENT '第四责责任网点区/县',
    duty_is_enable_4          varchar(100) COMMENT '第四责责任网点状态 0待启用,1启用,2禁用',
    duty_is_suspend_4         varchar(100) COMMENT '第四责责任网点是否暂停网点(1是,2否)',
    transfer_district_id_4    varchar(100) COMMENT '第四责任网点片区id',
    transfer_district_code_4  varchar(100) COMMENT '第四责任网点片区code',
    transfer_district_desc_4  varchar(100) COMMENT '第四责任网点片区desc',
    duty_virt_code_4          varchar(100) comment '第四责任网点虚拟代理区code(基础资料)',
    duty_virt_name_4          varchar(100) comment '第四责任网点虚拟代理区name(基础资料)',
    duty_is_virtual_agent_4   varchar(100) comment '第四责任网点是否是虚拟代理区1是',
    duty_manage_code_5        varchar(100) COMMENT '第五责任网点管理大区名称(基础资料)',
    duty_manage_name_5        varchar(100) COMMENT '第五责任网点管理大区名称(基础资料)',
    duty_regional_id_5        varchar(100) COMMENT '第五责任网点大区ID(基础资料)',
    duty_regional_desc_5      varchar(100) COMMENT '第五责任网点大区name(基础资料)',
    duty_agent_code_5         varchar(100) COMMENT '第五责任网点代理区编码(基础资料)',
    duty_agent_name_5         varchar(100) COMMENT '第五责任网点代理区编码(基础资料)',
    duty_network_type_5       varchar(100) COMMENT '第五责任网点类型(基础资料)',
    duty_provider_id_5        varchar(100) COMMENT '第五责责任网点省份ID(基础资料)',
    duty_provider_desc_5      varchar(100) COMMENT '第五责责任网点省份(基础资料)',
    duty_city_id_5            varchar(100) COMMENT '第五责责任网点城市ID(基础资料)',
    duty_city_desc_5          varchar(100) COMMENT '第五责责任网点城市(基础资料)',
    duty_area_id_5            varchar(100) COMMENT '第五责责任网点区/县id',
    duty_area_desc_5          varchar(100) COMMENT '第五责责任网点区/县',
    duty_is_enable_5          varchar(100) COMMENT '第五责责任网点状态 0待启用,1启用,2禁用',
    duty_is_suspend_5         varchar(100) COMMENT '第五责责任网点是否暂停网点(1是,2否)',
    transfer_district_id_5    varchar(100) COMMENT '第五责任网点片区id',
    transfer_district_code_5  varchar(100) COMMENT '第五责任网点片区code',
    transfer_district_desc_5  varchar(100) COMMENT '第五责任网点片区desc',
    duty_virt_code_5          varchar(100) comment '第五责任网点虚拟代理区code(基础资料)',
    duty_virt_name_5          varchar(100) comment '第五责任网点虚拟代理区name(基础资料)',
    duty_is_virtual_agent_5   varchar(100) comment '第五责任网点是否是虚拟代理区1是',
    pick_network_code         varchar(100) COMMENT '寄件网点code',
    pick_network_name         varchar(100) COMMENT '寄件网点',
    order_source_code         varchar(100) COMMENT '订单来源code',
    ordersource_name          varchar(100) COMMENT '订单来源',
    network_cnt               int(11) COMMENT '责任网点数',
    date_time                 date COMMENT '日期',
    damage_eliminate          varchar(100) COMMENT '是否剔除(质量): 1.是 2.否'
) ENGINE=OLAP
DUPLICATE KEY(work_type, waybill_no, resp_network_id, resp_network_code)
 COMMENT '破损率明细'
PARTITION BY RANGE(date_time)
(START ('2023-01-01') END ('2023-04-26') EVERY (INTERVAL 1 day)
)
DISTRIBUTED BY HASH(waybill_no) BUCKETS 1
PROPERTIES (
'replication_num' = '3',
'dynamic_partition.enable' = 'true',
'dynamic_partition.time_unit' = 'DAY',
'dynamic_partition.time_zone' = 'Asia/Shanghai',
'dynamic_partition.start' = '-180',
'dynamic_partition.end' = '3',
'dynamic_partition.prefix' = 'p',
'dynamic_partition.buckets' = '1',
'in_memory' = 'false',
'storage_format' = 'V2'
);

alter table jms_dm.dm_sqs_worn_waybill_detail_mid_dt
    add column (
    dispatch_network_code varchar (100) comment '派件code',
    dispatch_network_name varchar (100) comment '派件name',
    sender_province_id varchar (100) comment '寄件省份id',
    sender_province_name varchar (100) comment '寄件省份name',
    sender_city_id varchar (100) comment '寄件城市id',
    sender_city_name varchar (100) comment '寄件城市id',
    sb_virt_code varchar (100) comment '申报虚拟代理区code(基础资料)',
    sb_virt_name varchar (100) comment '申报虚拟代理区name(基础资料)',
    sb_zone_id varchar (100) comment '申报片区id(基础资料)',
    sb_zone_code varchar (100) comment '申报片区code(基础资料)',
    sb_zone_name varchar (100) comment '申报片区name(基础资料)',
    sb_agent_code varchar (100) comment '申报代理区code(基础资料)',
    sb_agent_name varchar (100) comment '申报代理区name(基础资料)',
    cost_center varchar (100) comment '成本中心',
    id varchar (100) comment '工单id',
    zcgoods_value varchar (100) comment '仲裁自带的物品价值',
    goods_type_code varchar (100) comment '物品类型code',
    goods_type_name varchar (100) comment '物品类型名称'
    );
